package com.shujia.map;

import java.io.File;
import java.util.Arrays;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/*
    每一个block块对应一个map任务，每一个map任务相当于一个线程
 */
public class MapTaskDemo {
    public static void main(String[] args) {

        //创建一个线程池
        ExecutorService pool = Executors.newFixedThreadPool(8);

        //获取所有的block块
        File file = new File("hadoop/data/blocks");

        //获取该目录下的所有文件
        File[] files = file.listFiles();

        //遍历得到每一个文件对象
        if(files!=null){
            for (File file1 : files) {
                //获取文件的编号
                String id = file1.getName().split("-")[1];

                //将每个block文件封装成线程对象，统计每个block块中的班级个数
                pool.submit(new MapRunnable(file1,id));
            }
        }

        pool.shutdown();

    }
}
